package com.zhuzhe.mq.service;

/**
 * @author whh
 * @date 2020/08/24 20:32
 */
public class MQBaseService {

    public void send(String service, String dataType, Object message, boolean sendAll) {

    }

    /**
     * 发送消息给调度中心
     * 
     * @param dataType
     * @param message
     * @param sendAll
     */
    public void sendToDispatchCenter(String dataType, Object message, boolean sendAll) {
        send("dispatchCenter", dataType, message, sendAll);
    }

    /**
     * 发送消息给调度中心 sendAll为false
     * 
     * @param dataType
     * @param message
     */
    public void sendToDispatchCenter(String dataType, Object message) {
        sendToDispatchCenter(dataType, message, false);
    }

    // /**
    // * 根据datatype获取队列相关信息
    // *
    // * @param dataType
    // * @return
    // */
    // public List<MQServiceProperties> getNameByDataType(String dataType) {
    // List<MQServiceProperties> nameList = new ArrayList<>();
    // List<MQServiceProperties> serviceList = mqServiceConfig.getServiceList();
    // for (int i = 0; i < serviceList.size(); i++) {
    // MQServiceProperties mqServiceProperties = serviceList.get(i);
    // List<String> dataTypeList = mqServiceProperties.getDataTypeList();
    // if (dataTypeList.contains(dataType)) {
    // nameList.add(mqServiceProperties);
    // }
    // }
    // return nameList;
    // }
}
